/**
 * @Author 安广伟
 * @Date 2024/7/17 14:26
 * @LastEditTime 2024-07-17 14:26:56
 * @Version 1.0
 * @Description:
 */

package com.example.demo.rabbitmq.customer;

import com.example.demo.rabbitmq.config.RabbitConfig;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class InsuranceDataCustomer {

    @RabbitListener(queues = RabbitConfig.INSURANCE_QUEUE)
    public void process(String testMessage){
//        long deliveryTag = testMessage.getMessageProperties().getDeliveryTag();
//        String s = new String(testMessage.getBody(), StandardCharsets.UTF_8);
        System.out.println("接收到的消息是：==========" + testMessage);
    }
}
